<?php
require_once("./banco/BancoMysql.php");
require "./base/Mensagem.php";

class RepositorioMensagem {

	private $mensagem;
	private $db;

	public function __construct($db = "MySQL") {
		$this->setDb($db);
	}

	public function setDb($valor) {
		$banco = "Banco" . $valor;
		$this->db = new $banco ();

		$this->db->setDb('weegodb');
	}

			
	public function selecionarMensagem($mensagem=null, $idusuario) {
		$this->db->abrirConexao();
		$sql =  "SELECT M.ID, M.DATAMENSAGEM, M.TITULO, M.SITUACAO, M.PRIORIDADE, M.TIPOMENSAGEM, M.STATUS, M.MENSAGEM, U.NOME ".
				"FROM mensagem M ".
				"JOIN membro_projeto_mensagem MPM on (MPM.MENSAGEM_ID = M.ID) ".
				"JOIN membro_projeto MP on (MP.ID = MPM.MEMBRO_PROJETO_ID) ".
				"JOIN membro_projeto MPR on (MPR.ID = M.MEMBRO_PROJETO_ID) ".
				"JOIN usuario U on (U.ID = MPR.USUARIO_ID) ".
				"WHERE MP.USUARIO_ID = ".$idusuario; 
		
		//echo $sql;
		
		if ( $this->db->executaConsulta($sql) ) {
			$matrizResult = $this->db->getResultSet();				
			return $matrizResult;
		} else {
			return null;
		}
		
		$this->db->fecharConexao();
	}		
	
}
?>
